package com.c.rabbit_mq.impl;

import cn.hutool.log.StaticLog;
import com.c.rabbit_mq.ComRabbitMqHandle;

public class Test extends ComRabbitMqHandle<String> {

    public static final String TOPIC = "test";

    public Test() {
        super(TOPIC, String.class);
    }

    @Override
    public void handle(String topic, String s) {
        StaticLog.info("消息消费");
    }

    public static void main(String[] args) {
        new Test().start_rabbit_mq_listen();

//        ComMqttManager.pushMsg(TOPIC, "test");
    }
}
